package com.mtiiot.fscore.inter1;

import com.mtiiot.fscore.bean.MetadataInfo;
import com.mtiiot.fscore.bean.MqInfo;

/**
 * fs服务接口版本1.1
 * 异步消息队列服务(用kafka队列作消息队列)
 * Created by Administrator on 16-7-22.
 */
public interface KafkaMqService1 {
      /**
       * 生产单条消息
       * @param metadataInfo 元数据信息
       * @param mqInfo
       * @return int 成功的消息条数
      */
      public int produceMessage(MetadataInfo metadataInfo, MqInfo mqInfo);

}
